org.springframework.web.reactive.function

Class BodyInserters

java.lang.Object

org.springframework.web.reactive.function.BodyInserters

public abstract class BodyInserters
extends java.lang.Object

Implementations of BodyInserter that write various bodies, such a reactive streams, server-sent events, resources, etc.

Since:

5.0

Author:

Arjen Poutsma

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	BodyInserters.DefaultFormInserter
private static class	BodyInserters.DefaultMultipartInserter
static interface	BodyInserters.FormInserter<T> Extension of BodyInserter that allows for adding form data or multipart form data.
static interface	BodyInserters.MultipartInserter Extension of BodyInserters.FormInserter that allows for adding asynchronous parts.

Field Summary

Fields

Modifier and Type	Field and Description
private static BodyInserter<java.lang.Void,ReactiveHttpOutputMessage>	EMPTY
private static ResolvableType	FORM_TYPE
private static ResolvableType	MULTIPART_VALUE_TYPE
private static ResolvableType	RESOURCE_TYPE
private static ResolvableType	SERVER_SIDE_EVENT_TYPE

Constructor Summary

Constructors

Constructor and Description
BodyInserters()

Method Summary

Modifier and Type	Method and Description
private static <T,P extends <any>,M extends ReactiveHttpOutputMessage> BodyInserter<T,M>	bodyInserterFor(P body, ResolvableType bodyType)
private static <T> HttpMessageWriter<T>	cast(HttpMessageWriter<?> messageWriter)
static <T> BodyInserter<T,ReactiveHttpOutputMessage>	empty() Return an empty BodyInserter that writes nothing.
private static <T> HttpMessageWriter<T>	findMessageWriter(BodyInserter.Context context, ResolvableType type, MediaType mediaType)
static <T extends <any>> BodyInserter<T,ReactiveHttpOutputMessage>	fromDataBuffers(T publisher) Return a BodyInserter that writes the given Publisher<DataBuffer> to the body.
static BodyInserters.FormInserter<java.lang.String>	fromFormData(MultiValueMap<java.lang.String,java.lang.String> formData) Return a BodyInserters.FormInserter that writes the given MultiValueMap as URL-encoded form data.
static BodyInserters.FormInserter<java.lang.String>	fromFormData(java.lang.String name, java.lang.String value) Return a BodyInserters.FormInserter that writes the given key-value pair as URL-encoded form data.
static <T,P extends <any>> BodyInserters.MultipartInserter	fromMultipartAsyncData(java.lang.String name, P publisher, java.lang.Class<T> elementClass) Return a BodyInserters.MultipartInserter that writes the given asynchronous parts, as multipart data.
static <T,P extends <any>> BodyInserters.MultipartInserter	fromMultipartAsyncData(java.lang.String name, P publisher, ParameterizedTypeReference<T> typeReference) Variant of #fromMultipartAsyncData(String, Publisher, Class) that accepts a ParameterizedTypeReference for the element type, which allows specifying generic type information.
static BodyInserters.MultipartInserter	fromMultipartData(MultiValueMap<java.lang.String,?> multipartData) Return a BodyInserters.MultipartInserter that writes the given MultiValueMap as multipart data.
static BodyInserters.MultipartInserter	fromMultipartData(java.lang.String name, java.lang.Object value) Return a BodyInserters.MultipartInserter that writes the given parts, as multipart data.
static <T> BodyInserter<T,ReactiveHttpOutputMessage>	fromObject(T body) Return a BodyInserter that writes the given single object.
static <T,P extends <any>> BodyInserter<P,ReactiveHttpOutputMessage>	fromPublisher(P publisher, java.lang.Class<T> elementClass) Return a BodyInserter that writes the given Publisher.
static <T,P extends <any>> BodyInserter<P,ReactiveHttpOutputMessage>	fromPublisher(P publisher, ParameterizedTypeReference<T> typeReference) Return a BodyInserter that writes the given Publisher.
static <T extends Resource> BodyInserter<T,ReactiveHttpOutputMessage>	fromResource(T resource) Return a BodyInserter that writes the given Resource.
static <T,S extends <any>> BodyInserter<S,ServerHttpResponse>	fromServerSentEvents(S eventsPublisher) Return a BodyInserter that writes the given ServerSentEvent publisher.
private static HttpMessageWriter<Resource>	resourceHttpMessageWriter(BodyInserter.Context context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RESOURCE_TYPE

private static final ResolvableType RESOURCE_TYPE

SERVER_SIDE_EVENT_TYPE

private static final ResolvableType SERVER_SIDE_EVENT_TYPE

FORM_TYPE

private static final ResolvableType FORM_TYPE

MULTIPART_VALUE_TYPE

private static final ResolvableType MULTIPART_VALUE_TYPE

EMPTY

private static final BodyInserter<java.lang.Void,ReactiveHttpOutputMessage> EMPTY

Constructor Detail

BodyInserters

public BodyInserters()

Method Detail

empty

public static <T> BodyInserter<T,ReactiveHttpOutputMessage> empty()

Return an empty BodyInserter that writes nothing.

Returns:

an empty BodyInserter

fromObject

public static <T> BodyInserter<T,ReactiveHttpOutputMessage> fromObject(T body)

Return a BodyInserter that writes the given single object.

Note also that WebClient and ServerResponse each offer a syncBody(Object) shortcut for providing an Object as the body.

Parameters:

body - the body of the response

Returns:

a BodyInserter that writes a single object

fromPublisher

public static <T,P extends <any>> BodyInserter<P,ReactiveHttpOutputMessage> fromPublisher(P publisher,
                                                                                          java.lang.Class<T> elementClass)

Return a BodyInserter that writes the given Publisher.

Note also that WebClient and ServerResponse each offer body shortcut methods for providing a Publisher as the body.

Type Parameters:

T - the type of the elements contained in the publisher

P - the type of the Publisher

Parameters:

publisher - the publisher to stream to the response body

elementClass - the class of elements contained in the publisher

Returns:

a BodyInserter that writes a Publisher

fromPublisher

public static <T,P extends <any>> BodyInserter<P,ReactiveHttpOutputMessage> fromPublisher(P publisher,
                                                                                          ParameterizedTypeReference<T> typeReference)

Return a BodyInserter that writes the given Publisher.

Note also that WebClient and ServerResponse each offer body shortcut methods for providing a Publisher as the body.

Type Parameters:

T - the type of the elements contained in the publisher

P - the type of the Publisher

Parameters:

publisher - the publisher to stream to the response body

typeReference - the type of elements contained in the publisher

Returns:

a BodyInserter that writes a Publisher

fromResource

public static <T extends Resource> BodyInserter<T,ReactiveHttpOutputMessage> fromResource(T resource)

Return a BodyInserter that writes the given Resource.

If the resource can be resolved to a file, it will be copied using zero-copy.

Type Parameters:

T - the type of the Resource

Parameters:

resource - the resource to write to the output message

Returns:

a BodyInserter that writes a Publisher

resourceHttpMessageWriter

private static HttpMessageWriter<Resource> resourceHttpMessageWriter(BodyInserter.Context context)

fromServerSentEvents

public static <T,S extends <any>> BodyInserter<S,ServerHttpResponse> fromServerSentEvents(S eventsPublisher)

Return a BodyInserter that writes the given ServerSentEvent publisher.

Note that a SSE BodyInserter can also be obtained by passing a stream of strings or POJOs (to be encoded as JSON) to #fromPublisher(Publisher, Class), and specifying a text/event-stream Content-Type.

Type Parameters:

T - the type of the elements contained in the ServerSentEvent

Parameters:

eventsPublisher - the ServerSentEvent publisher to write to the response body

Returns:

a BodyInserter that writes a ServerSentEvent publisher

See Also:

Server-Sent Events W3C recommendation

fromFormData

public static BodyInserters.FormInserter<java.lang.String> fromFormData(MultiValueMap<java.lang.String,java.lang.String> formData)

Return a BodyInserters.FormInserter that writes the given MultiValueMap as URL-encoded form data. The returned inserter allows for additional entries to be added via BodyInserters.FormInserter.with(String, Object).

Note that you can also use the syncBody(Object) method in the request builders of both the WebClient and WebTestClient. In that case the setting of the request content type is also not required, just be sure the map contains String values only or otherwise it would be interpreted as a multipart request.

Parameters:

formData - the form data to write to the output message

Returns:

the inserter that allows adding more form data

fromFormData

public static BodyInserters.FormInserter<java.lang.String> fromFormData(java.lang.String name,
                                                                        java.lang.String value)

Return a BodyInserters.FormInserter that writes the given key-value pair as URL-encoded form data. The returned inserter allows for additional entries to be added via BodyInserters.FormInserter.with(String, Object).

Parameters:

name - the key to add to the form

value - the value to add to the form

Returns:

the inserter that allows adding more form data

fromMultipartData

public static BodyInserters.MultipartInserter fromMultipartData(MultiValueMap<java.lang.String,?> multipartData)

Return a BodyInserters.MultipartInserter that writes the given MultiValueMap as multipart data. Values in the map can be an Object or an HttpEntity.

Note that you can also build the multipart data externally with MultipartBodyBuilder, and pass the resulting map directly to the syncBody(Object) shortcut method in WebClient.

Parameters:

multipartData - the form data to write to the output message

Returns:

the inserter that allows adding more parts

See Also:

MultipartBodyBuilder

fromMultipartData

public static BodyInserters.MultipartInserter fromMultipartData(java.lang.String name,
                                                                java.lang.Object value)

Return a BodyInserters.MultipartInserter that writes the given parts, as multipart data. Values in the map can be an Object or an HttpEntity.

Note that you can also build the multipart data externally with MultipartBodyBuilder, and pass the resulting map directly to the syncBody(Object) shortcut method in WebClient.

Parameters:

name - the part name

value - the part value, an Object or HttpEntity

Returns:

the inserter that allows adding more parts

fromMultipartAsyncData

public static <T,P extends <any>> BodyInserters.MultipartInserter fromMultipartAsyncData(java.lang.String name,
                                                                                         P publisher,
                                                                                         java.lang.Class<T> elementClass)

Return a BodyInserters.MultipartInserter that writes the given asynchronous parts, as multipart data.

Note that you can also build the multipart data externally with MultipartBodyBuilder, and pass the resulting map directly to the syncBody(Object) shortcut method in WebClient.

Parameters:

name - the part name

publisher - the publisher that forms the part value

elementClass - the class contained in the publisher

Returns:

the inserter that allows adding more parts

fromMultipartAsyncData

public static <T,P extends <any>> BodyInserters.MultipartInserter fromMultipartAsyncData(java.lang.String name,
                                                                                         P publisher,
                                                                                         ParameterizedTypeReference<T> typeReference)

Variant of #fromMultipartAsyncData(String, Publisher, Class) that accepts a ParameterizedTypeReference for the element type, which allows specifying generic type information.

Note that you can also build the multipart data externally with MultipartBodyBuilder, and pass the resulting map directly to the syncBody(Object) shortcut method in WebClient.

Parameters:

name - the part name

publisher - the publisher that forms the part value

typeReference - the type contained in the publisher

Returns:

the inserter that allows adding more parts

fromDataBuffers

public static <T extends <any>> BodyInserter<T,ReactiveHttpOutputMessage> fromDataBuffers(T publisher)

Return a BodyInserter that writes the given Publisher<DataBuffer> to the body.

Type Parameters:

T - the type of the publisher

Parameters:

publisher - the data buffer publisher to write

Returns:

a BodyInserter that writes directly to the body

See Also:

ReactiveHttpOutputMessage#writeWith(Publisher)

bodyInserterFor

private static <T,P extends <any>,M extends ReactiveHttpOutputMessage> BodyInserter<T,M> bodyInserterFor(P body,
                                                                                                         ResolvableType bodyType)

findMessageWriter

private static <T> HttpMessageWriter<T> findMessageWriter(BodyInserter.Context context,
                                                          ResolvableType type,
                                                          MediaType mediaType)

cast

private static <T> HttpMessageWriter<T> cast(HttpMessageWriter<?> messageWriter)